package com.lxy.cloud.mqtt.client.service.impl;

import com.lxy.cloud.mqtt.client.constant.SystemConstant;
import com.lxy.cloud.mqtt.client.model.dto.BaseMqttDTO;
import com.lxy.cloud.mqtt.client.model.dto.MqttEventDTO;
import com.lxy.cloud.mqtt.client.model.dto.VehicleInfoUploadDTO;
import com.lxy.cloud.mqtt.client.service.AbstractMessageProcessService;
import org.springframework.stereotype.Service;

/**
 * @Author: lxy
 * @Date: 2020/9/7 15:02
 * @Desc: 处理车端发送过来的车辆信息上传
 */
@Service(value = SystemConstant.LOGISTICS_DATA_UPLOAD)
public class VehicleInfoUpLoadProcessServiceImpl extends AbstractMessageProcessService<MqttEventDTO<VehicleInfoUploadDTO>> {
    @Override
    protected MqttEventDTO<VehicleInfoUploadDTO> convertMessage(BaseMqttDTO request) {
        return null;
    }

    @Override
    protected void process(MqttEventDTO<VehicleInfoUploadDTO> acpMessage) {
        System.out.println("acpMessage = " + acpMessage);
    }

}
